package com.xinghou.mq.consumer;

import org.apache.log4j.Logger;

import com.xinghou.mq.StoreInterface;
import com.xinghou.platform.server.mq.MqMessage;

/**
 * 消费用户消息 store
 * 
 * @author zhangjinwen 2016年1月6日
 */
public class StoreConsumer extends AbstractConsumer {
	private StoreInterface storeMqInterface;

	public StoreConsumer() {
		storeMqInterface = this.getBean(StoreInterface.class);
	}


	protected  void doWork(String task) {
		String[] datas = task.split(":");
		storeMqInterface.update(Integer.parseInt(datas[0]), datas[1].equals("U"));
	}
	

}
